<?php
//声明一个路由键
$routingKey = 'key_1.queue_1';
//设置一个交换机名称
$exchangeName = 'exchange_4';

include 'connection.php';

//创建是个消息
for($i = 1;$i <= 1000; $i++){
    $msg = array(
        'data' => 'message_'.$i,
        'hello'=> 'world'
    );
    //发送消息到交换机，并返回发送结果
    //delivery_mode:2声明消息持久，持久的队列 + 持久的消息在rabbitmq重启后不会消失
    //代码执行完毕后进程会自动退出
    try {
        echo "Send Message:" . $ex->publish(json_encode($msg), $routingKey
                , AMQP_NOPARAM, array('delivery_mode' => 2)) . "\n";
    } catch (AMQPChannelException $e) {
        echo '创建消息通道异常：'.$e->getMessage();
        exit();
    } catch (AMQPConnectionException $e) {
        echo '创建连接异常：'.$e->getMessage();
        exit();
    } catch (AMQPExchangeException $e) {
        echo '创建交换机异常：'.$e->getMessage();
        exit();
    }
}

